51793149a04ee195796af325ebb298b933c053de,src/main/java/com/continuuity/data/operation/ttqueue/TTQueueNewOnVCTable.java,TTQueueNewOnVCTable,dequeue,#QueueConsumer#ReadPointer#,162
Before Change
}
// If QueueState is null, read the queue state from underlying storage.
QueueState queueState = consumer.getQueueState();
if(queueState == null) {
queueState = dequeueStrategy.constructQueueState(consumer, config, readPointer);
consumer.setQueueState(queueState);
After Change
}
// If QueueState is null, read the queue state from underlying storage.
QueueStateImpl queueState = getQueueStateImpl(consumer.getQueueState());
if(queueState == null) {
queueState = dequeueStrategy.constructQueueState(consumer, config, readPointer);
consumer.setQueueState(queueState);